package com.elinshaw.service.impl;

import com.elinshaw.proto.Request;
import com.elinshaw.proto.Response;
import com.elinshaw.service.MessageServiceGrpc;
import io.grpc.stub.StreamObserver;

/**
 * @author Administrator
 */
public class MessageServiceImpl extends MessageServiceGrpc.MessageServiceImplBase {

    @Override
    public void controlTerminal(Request request, StreamObserver<Response> responseObserver) {
        request.getTerminalId();
        Response response = Response.newBuilder().setResult("id123").build();
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }


}
